<?php
/*
 * email_validation.php
 *
 * @(#) $Header: /CVSROOT/harliane/protected/extensions/emailvalidator/emailvalidation/email_validation.php,v 1.2 2011-09-09 02:18:50 herve Exp $
 *
 */

class email_validation
{
	private $email_regular_expression="^([-!#\$%&'*+./0-9=?A-Z^_`a-z{|}~])+@([-!#\$%&'*+/0-9=?A-Z^_`a-z{|}~]+\\.)+[a-zA-Z]{2,6}\$";
	private $_NAMESERVERS = array();
	private $next_token='';
	private $preg;
	private $last_code='';

	public $timeout=0;
	public $data_timeout=0;
	public $localhost='';
	public $localuser='';
	public $debug=0;
	public $html_debug=0;
	public $exclude_address='';
	public $resolver = null;
	public $getmxrr = 'GetMXRR';
	public $isGetmxrrWorking = true;

	public function __construct($servers)
	{
	   $this->_NAMESERVERS = $servers;
      if (!function_exists('getmxrr')) {
         require_once(Yii::getPathOfAlias('application.extensions.emailvalidator').DIRECTORY_SEPARATOR.'emailvalidation'.DIRECTORY_SEPARATOR.'getmxrr_php.php');
         $this->resolver = new getmxrr_php($this->_NAMESERVERS);
      }
      else {
         //if (!$this->isGetmxrrWorking) {
         //   require_once(Yii::getPathOfAlias('application.extensions.emailvalidator').DIRECTORY_SEPARATOR.'emailvalidation'.DIRECTORY_SEPARATOR.'rrcompat.php');
         //   $this->resolver = new rrcompat($this->_NAMESERVERS);
         //}
         //else {
            $this->resolver = $this;
         //}
      }
	}

	private function GetMXRR($hostname, &$mxhosts, &$weight)
	{
	   return getmxrr($hostname, $mxhosts, $weight);
	}

	public function Tokenize($string, $separator="")
	{
		if (!strcmp($separator,'')) {
			$separator=$string;
			$string=$this->next_token;
		}
		for ($character=0; $character<strlen($separator); $character++) {
			if (gettype($position = strpos($string, $separator[$character])) == 'integer')
				$found = (isset($found) ? min($found, $position) : $position);
		}
		if (isset($found)) {
			$this->next_token = substr($string, $found+1);
			return(substr($string, 0, $found));
		}
		else {
			$this->next_token = '';
			return($string);
		}
	}

	public function OutputDebug($message)
	{
		$message .= "\n";
		if ($this->html_debug)
			$message = str_replace("\n", "<br />\n", htmlentities($message));
		echo $message;
		flush();
	}

	public function GetLine($connection)
	{
		for ($line='';;) {
			if (feof($connection))
				return(0);
			$line .= fgets($connection, 100);
			$length = strlen($line);
			if ($length>=2 && substr($line,$length-2,2) == "\r\n") {
				$line = substr($line,0,$length-2);
				if ($this->debug)
					$this->OutputDebug("S $line");
				return($line);
			}
		}
	}

	public function PutLine($connection,$line)
	{
		if ($this->debug)
			$this->OutputDebug("C $line");
		return(fputs($connection, "$line\r\n"));
	}

	public function ValidateEmailAddress($email)
	{
		if (isset($this->preg)) {
			if (strlen($this->preg))
				return(preg_match($this->preg, $email));
		}
		else {
			$this->preg = (function_exists("preg_match") ? "/".str_replace("/", "\\/", $this->email_regular_expression)."/" : "");
			return($this->ValidateEmailAddress($email));
		}
		return(eregi($this->email_regular_expression,$email) != 0);
	}

	public function ValidateEmailHost($email,&$hosts)
	{
		if (!$this->ValidateEmailAddress($email))
			return(0);
		$user = $this->Tokenize($email, '@');
		$domain = $this->Tokenize('');
		$hosts = $weights = array();

		$f = $this->getmxrr;
		if (method_exists($this->resolver, $f) && $this->resolver->$f($domain, $hosts, $weights)) {
         $mxhosts=array();
         for ($host=0; $host<count($hosts); $host++)
            $mxhosts[$weights[$host]]=$hosts[$host];
			ksort($mxhosts);
			for (reset($mxhosts), $host=0; $host<count($mxhosts); next($mxhosts), $host++)
				$hosts[$host] = $mxhosts[Key($mxhosts)];
		}
		else {
			if (strcmp($ip = @gethostbyname($domain), $domain)	&& (strlen($this->exclude_address) == 0 || strcmp(@gethostbyname($this->exclude_address), $ip)))
            $hosts[] = $domain;
      }
		return(count($hosts) != 0);
	}

	public function VerifyResultLines($connection, $code)
	{
		while (($line = $this->getline($connection))) {
			$this->last_code = $this->Tokenize($line, ' -');
			if (strcmp($this->last_code, $code))
				return(0);
			if (!strcmp(substr($line, strlen($this->last_code), 1), ' '))
				return(1);
		}
		return(-1);
	}

	public function ValidateEmailBox($email)
	{
		if (!$this->ValidateEmailHost($email, $hosts))
         return(0);
		if (!strcmp($localhost = $this->localhost, '') && !strcmp($localhost = getenv('SERVER_NAME'), '') && !strcmp($localhost=getenv('HOST'), ''))
		   $localhost = 'localhost';
		if (!strcmp($localuser=$this->localuser,'') && !strcmp($localuser=getenv('USERNAME'),'') && !strcmp($localuser = getenv('USER'), ''))
		   $localuser = 'root';
      for ($host=0; $host<count($hosts); $host++) {
			$domain = $hosts[$host];
			if (ereg('^[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}$', $domain))
				$ip = $domain;
			else {
				if ($this->debug)
					$this->OutputDebug("Resolving host name \"".$hosts[$host]."\"...");
				if (!strcmp($ip = @gethostbyname($domain), $domain)) {
					if ($this->debug)
						$this->OutputDebug("Could not resolve host name \"".$hosts[$host]."\".");
					continue;
				}
			}
			if (strlen($this->exclude_address) && !strcmp(@gethostbyname($this->exclude_address),$ip)) {
				if ($this->debug)
               $this->OutputDebug("Host address of \"".$hosts[$host]."\" is the exclude address");
            continue;
         }
			if ($this->debug)
				$this->OutputDebug("Connecting to host address \"".$ip."\"...");
			if (($connection = ($this->timeout ? @fsockopen($ip, 25, $errno, $error, $this->timeout) : @fsockopen($ip, 25)))) {
				$timeout = ($this->data_timeout ? $this->data_timeout : $this->timeout);
				if ($timeout && function_exists('socket_set_timeout'))
					socket_set_timeout($connection, $timeout, 0);
				if ($this->debug)
               $this->OutputDebug("Connected.");
				if ($this->VerifyResultLines($connection,"220") > 0
				     && $this->PutLine($connection,"HELO $localhost")
				     && $this->VerifyResultLines($connection,"250") > 0
				     && $this->PutLine($connection,"MAIL FROM: <$localuser@$localhost>")
				     && $this->VerifyResultLines($connection,"250") > 0
				     && $this->PutLine($connection,"RCPT TO: <$email>")
				     && ($result=$this->VerifyResultLines($connection,"250")) >= 0) {
					if ($result) {
						if ($this->PutLine($connection,"DATA"))
							$result = ($this->VerifyResultLines($connection,"354") != 0);
					}
					else {
						if (strlen($this->last_code) && !strcmp($this->last_code[0], '4'))
							$result=-1;
					}
					if ($this->debug)
						$this->OutputDebug("This host states that the address is ".($result ? ($result>0 ? "valid" : "undetermined") : "not valid").".");
					fclose($connection);
					if ($this->debug)
						$this->OutputDebug("Disconnected.");
					return($result);
				}
				if ($this->debug)
					$this->OutputDebug("Unable to validate the address with this host.");
				fclose($connection);
				if ($this->debug)
					$this->OutputDebug("Disconnected.");
			}
			else {
				if($this->debug)
					$this->OutputDebug("Failed.");
			}
		}
		return(-1);
	}
};

?>